//package com.alibaba.cloud.examples.broadcast;
//
//import com.alibaba.cloud.examples.common.SimpleMsg;
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.context.annotation.Bean;
//import org.springframework.messaging.Message;
//import org.springframework.stereotype.Component;
//import java.util.function.Consumer;
//
//@Component
//public class ProjectMappingConsumer {
//
////    private static final Logger log = LoggerFactory
////            .getLogger(RocketMQBroadcastConsumer1Application.class);
//
//    @Bean
//    Consumer<Message<SimpleMsg>> consumer1111() {
//        return msg -> {
////            log.info("[onMessage][线程编号:{} 消息内容：{}]", Thread.currentThread().getId(), msg.getPayload().getMsg());
////            System.out.println(msg.getMsgText());
//        };
//    }
//}
